package com.msblearn.C_013;

import java.util.Random;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.TimeUnit;

/**
 * put:当满了会一直阻塞
 * add:当满了还添加会抛异常
 * offer：根据返回值判断是否添加成功。可以延时添加。
 */
public class T005_ArrayBlockingQueue {
    static BlockingQueue<String> strs = new ArrayBlockingQueue<>(10);
    static Random r = new Random();

    public static void main(String[] args) throws InterruptedException {
        for(int i=0;i<10;i++){
            strs.add("cc"+i);
        }
//        strs.put("aaa");
//        strs.add("aaa");
//        strs.offer("aaa");
        strs.offer("aaa",1, TimeUnit.SECONDS);
        System.out.println(strs);
    }

}
